package com.chis.flink;

import org.apache.flink.configuration.Configuration;
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction;
import org.apache.flink.streaming.api.functions.source.SourceFunction;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import java.util.List;

public class MysqlDdTest<FlinkTestBean> extends RichSinkFunction<com.chis.flink.FlinkTestBean> {
    public void open(Configuration parameters) throws Exception {

    }

    public void invoke(com.chis.flink.FlinkTestBean record) {
        System.out.println(record.getS1()+" "+record.getS2());
        
    }
}
